#!/usr/bin/env bash

day = $1

echo '清洗数据'

#数据清洗
spark-submit --class com.shujia.demo.Demo1DataFIlter --master yarn-client spark-1.0-SNAPSHOT.jar $day

echo '增加分区'
#增加分区
hive -e "alter table staypoint add if not exists partition(day='$day');"

echo '统计人流量 结果写入hbase'
#统计人流量 结果写入hbase
spark-submit --class com.shujia.demo.Demo2INdex --master yarn-client spark-1.0-SNAPSHOT-jar-with-dependencies.jar $day

